package com.tarena.lbs.marketing.web.mq;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author wen
 * @apiNote 消息推送MQ生产者
 * @since 2021/5/31
 */
public interface NoticeMessageInputSource {

    String IN_PUT = "notice-input";

    /**
     * 消息消费方法
     *
     * @return {@link SubscribableChannel}
     */
    @Input(IN_PUT)
    SubscribableChannel input();

}
